import os
os.environ["MODIN_ENGINE"] = "ray"  # Modin will use Ray
import numpy as np
import ray
ray.init(num_cpus=2)


if __name__ == '__main__':
    import modin.pandas as pd
    frame_data = np.random.randint(0, 100, size=(2**10, 2**8))
    df = pd.DataFrame(frame_data)
    print("====数据描述====\n", df)



#from distributed import Client
#client = Client(n_workers=2)
#import modin.pandas as pd
#
#if name == "main":
#
#path= "var/modin"
##modin_df = pd.read_parquet(path)
#modin_df = np.random.randint(0, 100, size=(2**10, 2**8))
#modin_df.to_parquet("var/test.parquet")
#print(f'Modin DF len = {len(modin_df)}')`

